package app.kafka;

/**
 * 测试使用
 * @author lfy.xys
 * @date 2018年5月3日
 *
 */
public interface KafkaPropertiesTest {
	final static String IP = "192.168.0.3";
	final static String zkConnect = IP + ":2181";//docker映射了端口，需要修改
//	final static String zkConnect = IP + ":32769";
	final static String groupId = "group-1";
	final static String kafkaServerURL = IP;
	final static int kafkaServerPort = 9092;//docker映射了端口，需要修改
//	final static int kafkaServerPort = 32777;
	final static int kafkaProducerBufferSize = 64 * 1024;
	final static int connectionTimeOut = 20000;
	final static int reconnectInterval = 10000;
	final static String topic1 = "topic1";
	final static String topic2 = "topic2";
	final static String topic3 = "topic3";
	final static String clientId = "SimpleConsumerDemoClient";
	final static String colon = ":";
}
